package cn.sunline.dreamvalue.entity;

import io.swagger.annotations.ApiModelProperty;
import java.io.Serializable;
import java.util.Date;

public class KafkaFailMsg implements Serializable {
    private Long id;

    @ApiModelProperty(value = "消息主题")
    private String topic;

    @ApiModelProperty(value = "分区")
    private Integer partitionNum;

    @ApiModelProperty(value = "kafka偏移量")
    private Long offsetNum;

    @ApiModelProperty(value = "消息key值")
    private String msgKey;

    @ApiModelProperty(value = "创建时间")
    private Date ctime;

    @ApiModelProperty(value = "消息体")
    private String msgValue;

    private static final long serialVersionUID = 1L;

    public Long getId() {
        return id;
    }

    public void setId(Long id) {
        this.id = id;
    }

    public String getTopic() {
        return topic;
    }

    public void setTopic(String topic) {
        this.topic = topic;
    }

    public Integer getPartitionNum() {
        return partitionNum;
    }

    public void setPartitionNum(Integer partitionNum) {
        this.partitionNum = partitionNum;
    }

    public Long getOffsetNum() {
        return offsetNum;
    }

    public void setOffsetNum(Long offsetNum) {
        this.offsetNum = offsetNum;
    }

    public String getMsgKey() {
        return msgKey;
    }

    public void setMsgKey(String msgKey) {
        this.msgKey = msgKey;
    }

    public Date getCtime() {
        return ctime;
    }

    public void setCtime(Date ctime) {
        this.ctime = ctime;
    }

    public String getMsgValue() {
        return msgValue;
    }

    public void setMsgValue(String msgValue) {
        this.msgValue = msgValue;
    }

    @Override
    public String toString() {
        StringBuilder sb = new StringBuilder();
        sb.append(getClass().getSimpleName());
        sb.append(" [");
        sb.append("Hash = ").append(hashCode());
        sb.append(", id=").append(id);
        sb.append(", topic=").append(topic);
        sb.append(", partitionNum=").append(partitionNum);
        sb.append(", offsetNum=").append(offsetNum);
        sb.append(", msgKey=").append(msgKey);
        sb.append(", ctime=").append(ctime);
        sb.append(", msgValue=").append(msgValue);
        sb.append(", serialVersionUID=").append(serialVersionUID);
        sb.append("]");
        return sb.toString();
    }
}